#include "Comm.hpp"

// void work()
// {
//     // 打开命名管道
//     int rfd = open("./fifo", 0666);
//     if (rfd < 0)
//     {
//         printf("open fifo fail, errno is %d, errinfo is %s\n", errno, strerror(errno));
//     }
//     // 写
//     string str;
//     while (1)
//     {
//         cout << "Please Enter Your Message:> ";
//         getline(cin, str);
//         // 如果用户输入quit，那就退出，然后关闭写端。
//         if(str == "quit")
//         {
//             cout << "client quit..." << endl;
//             break;
//         }
//         ssize_t n = write(rfd, str.c_str(), str.size());
//         if (n > 0)
//         {
//             cout << "Send Your Message Successfully" << endl;
//         }
//         else if(n == 0)
//         {
//             continue;
//         }
//         else
//         {
//             printf("write fifo fail, errno is %d, errinfo is %s\n", errno, strerror(errno));
//         }
//     }

//     // 关闭管道
//     close(rfd);
// }

int main()
{
    // 打开命名管道
    int rfd = open("./fifo", 0666);
    if (rfd < 0)
    {
        printf("open fifo fail, errno is %d, errinfo is %s\n", errno, strerror(errno));
    }
    // 写
    string str = "I am processA";
    ssize_t n = write(rfd, str.c_str(), str.size());
    if (n > 0)
    {
        cout << "Send Your Message Successfully" << endl;
    }
    else
    {
        printf("write fifo fail, errno is %d, errinfo is %s\n", errno, strerror(errno));
    }

    // 关闭管道
    close(rfd);
    return 0;
}